package pers.cz.logtail.queue.kafka;

import pers.cz.logtail.queue.AbstractQueueFactory;
import pers.cz.logtail.queue.Consumer;
import pers.cz.logtail.queue.Producer;
import pers.cz.logtail.queue.QueueConf;

/**
 * @program: JefLogTail
 * @description: kafka连接工厂
 * @author: Cheng Zhi
 * @create: 2023-03-15 14:01
 **/
public class KafkaFactory extends AbstractQueueFactory {

    private QueueConf queueConf;

    public KafkaFactory(QueueConf queueConf) {
        this.queueConf = queueConf;
    }

    @Override
    public Producer getProducer() {
        return new KafkaProducer(queueConf);
    }

    @Override
    public Consumer getConsumer() {
        return null;
    }
}
